package io.renren.modules.webctrl.controller;

import java.util.HashMap;
import java.util.Map;

import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * web端 对外的接口，此类为 状态接口 文档为 02_IOTP协议描述.doc - 2.5状态协议
 * 
 * @author lfy.xys
 * @date 2018年5月21日
 *
 */
@RestController
@RequestMapping("webctrl/statuscontroller")
public class StatusController {

	/** 设备的集合 */
	public static Map<Integer, Object> eqmMap = new HashMap<Integer, Object>();
	/** IOServer的集合 */
	public static Map<Integer, Object> IOSMap = new HashMap<Integer, Object>();

	/**
	 * 系统启动，使用runner实现 ，查询 设备 和 ioserver 的list，并遍历成 map
	 */
	public void creatMap() {

	}

	/**
	 * 
	 * 系统启动，使用runner实现 ，循环遍历eqmMap，IOSMap ，判断 状态的更新时间
	 */
	public void judgeStatus() {

	}

	/**
	 * 系统启动，使用runner实现 ，监听kafka的主题，并且得到最新的状态
	 * 用id当key。每次获得 协议，截取 设备/ios 的id，查看map中 的状态 和协议状态是否相同。不相同则入库，相同则跳过。均更新时间
	 * 
	 * 服务状态：http://domain/service_status/service_id/stauts_cpu_storageused-storagetotal_memused-memtotal_time
	 * 设备状态：http://domain/device_status/IOServer标识/分组标识/设备标识/status_lastonlinetime
	 */
	public void getKafka() {
		
	}
	
}
